cb0d432f358615b12a65eb62f4b03b70680b3575,modules/mqtt/src/main/java/org/apache/ignite/stream/mqtt/MqttStreamer.java,MqttStreamer,start,#,147

Before Change


                A.ensure(qualitiesOfService.isEmpty() || qualitiesOfService.size() == topics.size(), "qualities of " +
                    "service must be either empty or have the same size as topics list");

                cachedLogPrefix = "[" + Joiner.on(",").join(topics) + "]";
            }
            else {  // just the single topic
                topics.add(topic);

After Change


            logValues.put("clientId", clientId);

            // cache log values
            cachedLogValues = "[" + Joiner.on(", ").withKeyValueSeparator("=").join(logValues) + "]";

            // create logger
            log = getIgnite().log();